草庐IT

SpringCloud Stream整合RocketMQ

全部标签

SpringBoot 整合多数据源的事务问题

代码先贴代码:核心就是:Spring给我们提供的一个类AbstractRoutingDataSource,然后我们再写一个切面来切换数据源,肯定要有一个地方存储key还要保证上下文都可用,所以我们使用ThreadLocal来存储数据源的keypom.xmlorg.springframework.bootspring-boot-starter-aoporg.springframework.bootspring-boot-starter-webcom.alibabadruid-spring-boot-starter1.2.6注解:@Target({ElementType.TYPE,ElementT

Spring Boot3整合knife4j(swagger3)

目录1.前置条件2.导依赖3.配置1.前置条件已经初始化好一个springboot项目且版本为3X,项目可正常启动。作者版本为3.2.2初始化教程:新版idea创建springboot项目-CSDN博客https://blog.csdn.net/qq_62262918/article/details/135785412?spm=1001.2014.3001.55012.导依赖knife4j官网:Knife4j·集Swagger2及OpenAPI3为一体的增强解决方案.|Knife4j(xiaominfo.com)https://doc.xiaominfo.com/依赖选择:作者的使用的spri

Spring Boot集成RocketMQ全部种类消息实现+生产者和消费者配置信息介绍(内含5.x新增可自定义时间的定时/延时消息)

SpringBoot集成RocketMQ全部种类消息实现+生产者和消费者配置信息介绍内含5.x新增可自定义时间的定时/延时消息前言添加POM依赖添加application.yml配置信息创建公共示例对象(只看demo可忽略)消费者相关介绍ACK机制介绍@RocketMQMessageListener介绍参数介绍RocketMQListener接口介绍泛型问题使用MessageExt(可获取完整消息对象:消息体、消息ID、topic、queueId等)使用UserDTO(不需要完整消息对象直接使用消息体类型)发送单向消息生产者消费者发送同步消息(响应值为void)生产者消费者发送同步消息(响应值

【MongoDB】万字长文,命令与代码一一对应SpringBoot整合MongoDB之MongoTemplate

目录一、导入依赖与配置信息二、导入测试数据创建实体类三、插入数据1、Insert默认集合插入2、Insert指定集合插入 3、Insert批量插入数据  4、save默认集合插入5、save指定集合插入 6、insert与save的区别 四、修改数据1、修改符合条件的第一条数据2、全部修改五、删除数据1、删除满足条件的所有文档2、删除集合里所有文档3、删除满足条件的单个文档并返回4、删除满足条件的所有文档并返回六、查找数据1、查询全部文档2、查询指定id的文档3、查询满足条件的一条文档4、查询满足条件的所有文档5、And查询6、Or查询7、In查询8、比较查询9、正则查询10、排序查询11、分

Spring Boot 3.2.2整合MyBatis-Plus 3.5.5依赖不兼容问题

问题演示导依赖当你启动项目就会抛出该异常java.lang.IllegalArgumentException:Invalidvaluetypeforattribute'factoryBeanObjectType':java.lang.String问题原因mybatis-plus中 mybatis 的整合包版本不够导致的解决方案排除掉mybatis-plus中 mybatis 的整合包,单独引入一个高版本的(测试过不要低于2x版本)com.baomidoumybatis-plus-boot-starter3.5.5org.mybatismybatis-springorg.mybatismybat

Spring Boot整合Spring Security:构建安全的Web应用

文章目录1.添加依赖2.配置SpringSecurity3.创建用户服务4.控制器和视图5.运行应用SpringSecurity是一个强大的身份验证和访问控制框架,用于保护Spring应用程序。它提供了全面的安全服务,包括身份验证、授权、攻击防护等。本文将介绍如何在SpringBoot应用程序中整合SpringSecurity,以构建一个安全可靠的Web应用。1.添加依赖首先,需要在pom.xml文件中添加SpringSecurity的依赖:org.springframework.bootspring-boot-starter-security2.配置SpringSecurity在Spring

Elasticsearch与Hadoop的整合

1.背景介绍1.背景介绍Elasticsearch和Hadoop都是分布式搜索和大数据处理领域的重要技术。Elasticsearch是一个基于Lucene的搜索引擎,它具有实时搜索、分布式、可扩展和高性能等特点。Hadoop是一个分布式文件系统(HDFS)和分布式计算框架(MapReduce)的集合,用于处理大量数据。随着数据规模的不断增加,需要对大量数据进行实时搜索和分析。因此,将Elasticsearch与Hadoop整合在一起,可以充分发挥它们的优势,实现对大数据的高效处理和实时搜索。2.核心概念与联系在Elasticsearch与Hadoop的整合中,主要涉及以下几个核心概念:Elas

Eureka整合seata分布式事务

文章目录一、分布式事务存在的问题二、分布式事务理论三、认识SeataSeata分布式事务解决方案1、XA模式2、AT模式3、SAGA模式4.SAGA模式优缺点:5.四种模式对比四、微服务整合SeataAT案例Seata配置微服务整合2.1、父工程项目创建引入依赖2.2、Eureka集群搭建2.3、搭建账户微服务2.3.1新建seata-account-service微服务2.3.2引入依赖2.3.3seata事务用到的表2.3.4seata微服务配置2.3.5yml配置seata事务2.3.6数据源交给seata去代理2.3.7主启动类去掉默认自动加载数据源2.3.8业务数据dbDOdaose

ElasticSearch学习笔记-SpringBoot整合Elasticsearch7

项目最近需要接入Elasticsearch7,顺带记录下笔记。Elasticsearch依赖包版本properties>elasticsearch.version>7.9.3/elasticsearch.version>elasticsearch.rest.version>7.9.3/elasticsearch.rest.version>/properties>!--Elasticsearch依赖包-->dependency>groupId>org.elasticsearch/groupId>artifactId>elasticsearch/artifactId>version>${elast

RocketMQ x OpenTelemetry 分布式全链路追踪最佳实践

在分布式系统中,多个服务之间的交互涉及到复杂的网络通信和数据传输,其中每个服务可能由不同的团队或组织负责维护和开发。因此,在这样的环境下,当一个请求被发出并经过多个服务的处理后,如果出现了问题或错误,很难快速定位到根因。分布式全链路追踪技术则可以帮助我们解决这个问题,它能够跟踪和记录请求在系统中的传输过程,并提供详细的性能和日志信息,使得开发人员能够快速诊断和定位问题。对于分布式系统的可靠性、性能和可维护性起到了非常重要的作用。RocketMQ5.0与分布式全链路追踪ApacheRocketMQ5.0版本作为近几年来最大的一次迭代,在整个可观测性上也进行了诸多改进。其中,支持标准化的分布式全链